package com.xiaohu.sql

import org.apache.hadoop.hive.ql.exec.UDF

class Demo13Str extends UDF {
  def evaluate(line: String): String = "易政真帅：" + line

}

/**
 * 1、自定义类继承UDF类，重写evaluate方法
 * 2、打包，spark-1.0.jar 将jar包放到spark目录下的jars目录下
 * 3、在spark-sql命令行中注册函数
 * create function yzzs as 'com.shujia.sql.Demo13Str'
 *
 *
 * */
